package com.yy.springcloud.mq;

import com.yy.kit.log.YYLogKits;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * <p>
 * 消费者类
 * </p>
 *
 * @author 杨阳
 * @since 2017年12月11日
 */
@Component
public class Receiver {

    /**
     * <p>
     * 消费test.rabbitmq.queue队列中的消息
     * </p>
     *
     * @return {@link String}
     */
    @RabbitListener(queues = Params.QUEUE)
    public String process(String msg) {
        YYLogKits.printImportant(this.getClass(), "process--{}接收来自{}队列的消息：{}",
                Thread.currentThread().getName(), Params.QUEUE, msg);
        return msg;
    }

    /**
     * <p>
     * 配置一个跟上面一样的，试试能不能一起消费
     * </p>
     *
     * @return
     */
    @RabbitListener(queues = Params.QUEUE)
    //定时执行，一秒一次
    public String process3(String msg) {
        YYLogKits.printImportant(this.getClass(), "process3--{}接收来自{}队列的消息：{}",
                Thread.currentThread().getName(), Params.QUEUE, msg);
        return msg;
    }

    @RabbitListener(queues = Params.QUEUE2)
    public String process2(String msg) {
        YYLogKits.printImportant(this.getClass(), "process2--{}接收来自{}队列的消息：{}",
                Thread.currentThread().getName(), Params.QUEUE2, msg);
        return msg;
    }

}
